package com.star.common.mq.annotation;

import com.star.common.mq.config.BaseKafkaMqConfig;
import org.springframework.context.annotation.Import;

import java.lang.annotation.*;

/**
 * 开启kafka
 * @author zhouhengzhe
 */
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.TYPE})
@Documented
@Import(BaseKafkaMqConfig.class)
public @interface EnableKafkaMQ {
}
